package io.xxx.aurora.client.produce

import java.util.*
import java.util.concurrent.TimeUnit

fun main() {
    val props = Properties()
    props["bootstrap.servers"] = "localhost:9999"
    val producer = AuroraProducer(props)
    for (i in 1..10) {
        val record = ProducerRecord("test", i)
        producer.send(record)
        TimeUnit.MILLISECONDS.sleep(30)
    }
}